Node / meshtastic / Meshtastic-Android / files / core / data / src / commonMain / kotlin / org / meshtastic / core / data / manager / TelemetryPacketHandlerImpl.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.data.manager

Tff7b72import T7ee787co.touchlab.kermit.Logger

Tff7b72import T7ee787kotlinx.coroutines.CoroutineScope

Tff7b72import T7ee787kotlinx.coroutines.sync.Mutex

Tff7b72import T7ee787kotlinx.coroutines.sync.withLock

Tff7b72import T7ee787org.koin.core.annotation.Named

Tff7b72import T7ee787org.koin.core.annotation.Single

Tff7b72import T7ee787org.meshtastic.core.common.util.clampTimestampToNow

Tff7b72import T7ee787org.meshtastic.core.model.DataPacket

Tff7b72import T7ee787org.meshtastic.core.model.Node

Tff7b72import T7ee787org.meshtastic.core.model.util.decodeOrNull

Tff7b72import T7ee787org.meshtastic.core.model.util.toOneLiner

Tff7b72import T7ee787org.meshtastic.core.repository.MeshConnectionManager

Tff7b72import T7ee787org.meshtastic.core.repository.NodeManager

Tff7b72import T7ee787org.meshtastic.core.repository.Notification

Tff7b72import T7ee787org.meshtastic.core.repository.NotificationManager

Tff7b72import T7ee787org.meshtastic.core.repository.RadioInterfaceService

Tff7b72import T7ee787org.meshtastic.core.repository.RadioSessionContext

Tff7b72import T7ee787org.meshtastic.core.repository.TelemetryPacketHandler

Tff7b72import T7ee787org.meshtastic.core.resources.Res

Tff7b72import T7ee787org.meshtastic.core.resources.getStringSuspend

Tff7b72import T7ee787org.meshtastic.core.resources.low_battery_message

Tff7b72import T7ee787org.meshtastic.core.resources.low_battery_title

Tff7b72import T7ee787org.meshtastic.proto.MeshPacket

Tff7b72import T7ee787org.meshtastic.proto.Telemetry

Tff7b72import T7ee787kotlin.time.Duration.Companion.milliseconds

T8b949e/**

* Implementation of [TelemetryPacketHandler] that processes telemetry packets and manages battery-level notifications

* with cooldown logic.

*/

Tf0883e@Single

Tff7b72class T56d364TelemetryPacketHandlerImplTb4b4b4(

Tff7b72private Tff7b72val Te6edf3nodeManagerTb4b4b4: Te6edf3NodeManagerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3connectionManagerTb4b4b4: Te6edf3LazyTff7b72<Te6edf3MeshConnectionManagerTff7b72>Tb4b4b4,

Tff7b72private Tff7b72val Te6edf3notificationManagerTb4b4b4: Te6edf3NotificationManagerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3radioInterfaceServiceTb4b4b4: Te6edf3RadioInterfaceServiceTb4b4b4,

Tf0883e@NamedTb4b4b4(Ta5d6ff"Ta5d6ffServiceScopeTa5d6ff"Tb4b4b4) Tff7b72private Tff7b72val Te6edf3scopeTb4b4b4: Te6edf3CoroutineScopeTb4b4b4,

Tb4b4b4) Tb4b4b4: Te6edf3TelemetryPacketHandler Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3batteryMutex Tff7b72= Te6edf3MutexTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3notifiedNodes Tff7b72= Te6edf3mutableSetOfTff7b72<Tffa657IntTff7b72>Tb4b4b4(Tb4b4b4)

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffLongMethodTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffCyclomaticComplexMethodTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffReturnCountTa5d6ff"Tb4b4b4)

Tff7b72override Tff7b72fun Td2a8ffhandleTelemetryTb4b4b4(

Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4,

Te6edf3dataPacketTb4b4b4: Te6edf3DataPacketTb4b4b4,

Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4,

Te6edf3sessionTb4b4b4: Te6edf3RadioSessionContextTb4b4b4,

Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3payload Tff7b72= Te6edf3packetTb4b4b4.Te6edf3decodedTff7b72?.Te6edf3payload Tff7b72?: Tff7b72return

Tff7b72val Te6edf3telemetry Tff7b72=

Tb4b4b4(Te6edf3TelemetryTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3decodeOrNullTb4b4b4(Te6edf3payloadTb4b4b4, Te6edf3LoggerTb4b4b4) Tff7b72?: Tff7b72returnTb4b4b4)Tb4b4b4.Te6edf3let Tb4b4b4{

Tff7b72if Tb4b4b4(Tffa657itTb4b4b4.Te6edf3time Tff7b72=Tff7b72= T79c0ff0Tb4b4b4) Tffa657itTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3time Tff7b72= Tb4b4b4(Te6edf3dataPacketTb4b4b4.Te6edf3timeTb4b4b4.Te6edf3millisecondsTb4b4b4.Te6edf3inWholeSecondsTb4b4b4)Tb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)Tb4b4b4) Tff7b72else Tffa657it

Tb4b4b4}

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffTelemetry from Tffd700${Te6edf3packetTb4b4b4.Te6edf3fromTffd700}Ta5d6ff: Tffd700${Te6edf3TelemetryTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3toOneLinerTb4b4b4(Te6edf3telemetryTb4b4b4)Tffd700}Ta5d6ff" Tb4b4b4}

Tff7b72val Te6edf3fromNum Tff7b72= Te6edf3packetTb4b4b4.Te6edf3from

Tff7b72val Te6edf3isRemote Tff7b72= Te6edf3fromNum Tff7b72!Tff7b72= Te6edf3myNodeNum

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3isRemoteTb4b4b4) Te6edf3connectionManagerTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3updateTelemetryTb4b4b4(Te6edf3telemetryTb4b4b4)

Tff7b72val Te6edf3transformTb4b4b4: Tb4b4b4(Te6edf3NodeTb4b4b4) Tff7b72-Tff7b72> Te6edf3Node Tff7b72= Tb4b4b4{ Te6edf3node Tff7b72-Tff7b72>

Tff7b72var Te6edf3nextNode Tff7b72= Te6edf3node

Te6edf3telemetryTb4b4b4.Te6edf3device_metricsTff7b72?.Te6edf3let Tb4b4b4{ Te6edf3nextNode Tff7b72= Te6edf3nextNodeTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3deviceMetrics Tff7b72= Tffa657itTb4b4b4) Tb4b4b4}

Te6edf3telemetryTb4b4b4.Te6edf3environment_metricsTff7b72?.Te6edf3let Tb4b4b4{ Te6edf3nextNode Tff7b72= Te6edf3nextNodeTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3environmentMetrics Tff7b72= Tffa657itTb4b4b4) Tb4b4b4}

Te6edf3telemetryTb4b4b4.Te6edf3power_metricsTff7b72?.Te6edf3let Tb4b4b4{ Te6edf3nextNode Tff7b72= Te6edf3nextNodeTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3powerMetrics Tff7b72= Tffa657itTb4b4b4) Tb4b4b4}

Te6edf3telemetryTb4b4b4.Te6edf3air_quality_metricsTff7b72?.Te6edf3let Tb4b4b4{ Te6edf3nextNode Tff7b72= Te6edf3nextNodeTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3airQualityMetrics Tff7b72= Tffa657itTb4b4b4) Tb4b4b4}

Tff7b72val Te6edf3telemetryTime Tff7b72= Tff7b72if Tb4b4b4(Te6edf3telemetryTb4b4b4.Te6edf3time Tff7b72!Tff7b72= T79c0ff0Tb4b4b4) Te6edf3telemetryTb4b4b4.Te6edf3time Tff7b72else Te6edf3nextNodeTb4b4b4.Te6edf3lastHeard

Tff7b72val Te6edf3newLastHeard Tff7b72= Te6edf3clampTimestampToNowTb4b4b4(Te6edf3maxOfTb4b4b4(Te6edf3nextNodeTb4b4b4.Te6edf3lastHeardTb4b4b4, Te6edf3telemetryTimeTb4b4b4)Tb4b4b4)

Te6edf3nextNodeTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3lastHeard Tff7b72= Te6edf3newLastHeardTb4b4b4)

Tb4b4b4}

Te6edf3nodeManagerTb4b4b4.Te6edf3updateNodeForSessionTb4b4b4(Te6edf3fromNumTb4b4b4, Te6edf3sessionTb4b4b4, Te6edf3transform Tff7b72= Te6edf3transformTb4b4b4)

Tff7b72val Te6edf3metrics Tff7b72= Te6edf3telemetryTb4b4b4.Te6edf3device_metrics Tff7b72?: Tff7b72return

Tff7b72val Te6edf3updatedNode Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNumTff7b72[Te6edf3fromNumTff7b72] Tff7b72?: Tff7b72return

Tff7b72if Tb4b4b4(Te6edf3fromNum Tff7b72!Tff7b72= Te6edf3myNodeNum Tff7b72&Tff7b72& Tff7b72!Te6edf3updatedNodeTb4b4b4.Te6edf3isFavoriteTb4b4b4) Tff7b72return

Tff7b72if Tb4b4b4(

Tb4b4b4(Te6edf3metricsTb4b4b4.Te6edf3voltage Tff7b72?: T79c0ff0fTb4b4b4) Tff7b72> Te6edf3BATTERY_PERCENT_UNSUPPORTED Tff7b72&Tff7b72&

Tb4b4b4(Te6edf3metricsTb4b4b4.Te6edf3battery_level Tff7b72?: T79c0ff0Tb4b4b4) Tff7b72<Tff7b72= Te6edf3BATTERY_PERCENT_LOW_THRESHOLD

Tb4b4b4) Tb4b4b4{

Te6edf3radioInterfaceServiceTb4b4b4.Te6edf3launchSessionWorkTb4b4b4(Te6edf3scopeTb4b4b4, Te6edf3sessionTb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3shouldBatteryNotificationShowTb4b4b4(Te6edf3fromNumTb4b4b4, Te6edf3telemetryTb4b4b4, Te6edf3myNodeNumTb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3notificationManagerTb4b4b4.Te6edf3dispatchTb4b4b4(

Te6edf3NotificationTb4b4b4(

Te6edf3title Tff7b72= Te6edf3getStringSuspendTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3low_battery_titleTb4b4b4, Te6edf3updatedNodeTb4b4b4.Te6edf3userTb4b4b4.Te6edf3short_nameTb4b4b4)Tb4b4b4,

Te6edf3message Tff7b72=

Te6edf3getStringSuspendTb4b4b4(

Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3low_battery_messageTb4b4b4,

Te6edf3updatedNodeTb4b4b4.Te6edf3userTb4b4b4.Te6edf3long_nameTb4b4b4,

Te6edf3updatedNodeTb4b4b4.Te6edf3deviceMetricsTb4b4b4.Te6edf3battery_level Tff7b72?: T79c0ff0Tb4b4b4,

Tb4b4b4)Tb4b4b4,

Te6edf3category Tff7b72= Te6edf3NotificationTb4b4b4.Te6edf3CategoryTb4b4b4.Te6edf3BatteryTb4b4b4,

Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3radioInterfaceServiceTb4b4b4.Te6edf3launchSessionWorkTb4b4b4(Te6edf3scopeTb4b4b4, Te6edf3sessionTb4b4b4) Tb4b4b4{

Te6edf3batteryMutexTb4b4b4.Te6edf3withLock Tb4b4b4{ Te6edf3notifiedNodesTb4b4b4.Te6edf3removeTb4b4b4(Te6edf3fromNumTb4b4b4) Tb4b4b4}

Te6edf3notificationManagerTb4b4b4.Te6edf3cancelTb4b4b4(Te6edf3updatedNodeTb4b4b4.Te6edf3numTb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tb4b4b4}

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffUnusedParameterTa5d6ff"Tb4b4b4)

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffshouldBatteryNotificationShowTb4b4b4(Te6edf3fromNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3tTb4b4b4: Te6edf3TelemetryTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Tffa657Boolean Tb4b4b4{

Te6edf3batteryMutexTb4b4b4.Te6edf3withLock Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3fromNum Tff7b72in Te6edf3notifiedNodesTb4b4b4) Tff7b72return Tff7b72false

Te6edf3notifiedNodesTb4b4b4.Te6edf3addTb4b4b4(Te6edf3fromNumTb4b4b4)

Tb4b4b4}

Tff7b72return Tff7b72true

Tb4b4b4}

Tff7b72companion Tff7b72object Tb4b4b4{

Tff7b72private Tff7b72const Tff7b72val Te6edf3BATTERY_PERCENT_UNSUPPORTED Tff7b72= T79c0ff0.0

Tff7b72private Tff7b72const Tff7b72val Te6edf3BATTERY_PERCENT_LOW_THRESHOLD Tff7b72= T79c0ff2T79c0ff0

Tb4b4b4}

Tb4b4b4}